google.golang.org/grpc/internal/transport.http2Client.activeStreams (field)
15 uses
google.golang.org/grpc/internal/transport (current package)
http2_client.go#L119: activeStreams map[uint32]*Stream
http2_client.go#L334: activeStreams: make(map[uint32]*Stream),
http2_client.go#L792: if t.activeStreams == nil { // Can be niled from Close().
http2_client.go#L796: t.activeStreams[s.id] = s
http2_client.go#L919: if t.activeStreams != nil {
http2_client.go#L920: delete(t.activeStreams, s.id)
http2_client.go#L971: streams := t.activeStreams
http2_client.go#L972: t.activeStreams = nil
http2_client.go#L1024: active := len(t.activeStreams)
http2_client.go#L1060: s := t.activeStreams[f.Header().StreamID]
http2_client.go#L1090: for _, s := range t.activeStreams {
http2_client.go#L1316: if len(t.activeStreams) == 0 {
http2_client.go#L1323: for streamID, stream := range t.activeStreams {
http2_client.go#L1607: s := t.activeStreams[se.StreamID]
http2_client.go#L1697: if len(t.activeStreams) < 1 && !t.kp.PermitWithoutStream {
The pages are generated with Golds v0.4.9. (GOOS=linux GOARCH=amd64)